package gspushmq.v1.main;

import ggjob.job.Bootstrap;
import ggjob.job.Schedulers;
import gspushmq.v1.app.producerapp.job.GGDehydrateJob;
import gspushmq.v1.consumer.OnlineConsumerJob;
import gspushmq.v1.produce.job.HeartbeatJob;
import gspushmq.v1.produce.job.api.GGProduceApiJob;
import gspushmq.v1.produce.job.sys.*;
import gspushmq.v1.produce.job.wb.GGWbJob;
import gspushmq.v1.save.log.LogWriteJob;


public class GGPushEngineMesJob {

	public static void start(){
		//定时开始调

		/*Schedulers.scheds.addScheduler(HeartbeatJob.class, "0/10 * * * * ?");//服务端心跳
		Schedulers.scheds.addSchedulerStartNow(LogWriteJob.class);//日志任务
		Schedulers.scheds.addSchedulerStartNow(OnlineConsumerJob.class);//在线消费

		Schedulers.scheds.addScheduler(GGWbJob.class, "0 0/1 * * * ?");
		Schedulers.scheds.addScheduler(GGVipStockInOutJob.class, "0/50 * * * * ?");
		Schedulers.scheds.addScheduler(GGMyOrderVideoJob.class, "0 0/5 * * * ?");
		Schedulers.scheds.addScheduler(GGMyStockTagsJob.class, "0 5/30 * * * ?");
		Schedulers.scheds.addScheduler(GGValuationJob.class, "0 30 7 * * ?");
		Schedulers.scheds.addScheduler(GGSysBackMessageJob.class, "0 0/2 * * * ?");
		Schedulers.scheds.addScheduler(GGProduceApiJob.class, "0 0/30 * * * ?");
		Schedulers.scheds.addScheduler(GGDehydrateJob.class, "0/15 * * * * ?");
		Schedulers.scheds.addScheduler(GGWeeklyreportJob.class, "0 0 10 ? * SAT");*/

		Schedulers.scheds.addScheduler(GGProduceApiJob.class, "0/30 * * * * ?");
		
		Bootstrap.start();
	}
	
	
	/*public static void close(){
		Schedulers.scheds.delete(APICountJob.class);
		Schedulers.scheds.delete(APIPushToUserJob.class);
	}*/
}
